# 将从 hive 上下载的快讯处理成训练 LDA 模型的语料

import sys

from ..convert_dataset2corpus import process_kuaixun_csv_corpus


def run():
    csv_fp = sys.argv[2]
    save_fp = sys.argv[3]
    process_kuaixun_csv_corpus(csv_fp, save_fp)
